package com.example.universitylibraryback.pipeline;

import java.util.concurrent.BlockingQueue;

/**
 * 过滤器泛型接口
 * @param <T>处理的数据类型
 */
@FunctionalInterface
public interface Filter<T> {
    void process(BlockingQueue<T> inputQueue, BlockingQueue<T> outputQueue) throws InterruptedException;
}